package com.erbantou.filemanage.progress;

import org.springframework.messaging.simp.stomp.StompSession;
import org.springframework.messaging.simp.stomp.StompSessionHandlerAdapter;

import java.util.concurrent.CompletableFuture;

public class StompClient {
    public CompletableFuture<StompSession> connect(String url, StompSessionHandlerAdapter handler) {
        // 实现连接逻辑并返回 CompletableFuture<StompSession>
        // 这里需要根据具体的 WebSocket 客户端库实现连接逻辑
        return new CompletableFuture<>();
    }
}